package com.cnebula.dataprocess.common.hive;

import java.io.Serializable;

import com.cnebula.dataprocess.common.JobPayload;

public class HiveLoadData extends JobPayload implements Serializable {

	/**
	 * 
	 */
	private static final long serialVersionUID = 1L;

	private String datafile;

	private String hiveTable;

	private int overwrite = 1; // 1 覆盖 0 增量新增

	public String getDatafile() {
		return datafile;
	}

	public void setDatafile(String datafile) {
		this.datafile = datafile;
	}

	public String getHiveTable() {
		return hiveTable;
	}

	public void setHiveTable(String hiveTable) {
		this.hiveTable = hiveTable;
	}

	public int getOverwrite() {
		return overwrite;
	}

	public void setOverwrite(int overwrite) {
		this.overwrite = overwrite;
	}

}
